package service

// import (
// 	"FlowMaster/model"
// 	"database/sql"
// 	"fmt"

// 	_ "github.com/mattn/go-sqlite3"
// )

// func ConnDB() *sql.DB {
// 	// 连接到SQLite数据库
// 	db, err := sql.Open("sqlite3", "access_tokens.db")
// 	if err != nil {
// 		fmt.Println("数据库连接失败:", err)
// 	}
// 	return db
// }

// func CreateDB(db *sql.DB) error {
// 	defer db.Close()
// 	// 创建access_tokens表
// 	_, err := db.Exec(`CREATE TABLE IF NOT EXISTS access_tokens (
// 		id INTEGER PRIMARY KEY AUTOINCREMENT,
// 		access_token TEXT NOT NULL,
// 		token_type TEXT NOT NULL,
// 		expires_in TEXT NOT NULL
// 	)`)
// 	if err != nil {
// 		fmt.Println("创建表失败:", err)
// 		return err
// 	}
// 	return nil
// }

// func SelectDb(db *sql.DB) (*model.TokenData, error) {
// 	defer db.Close()
// 	var tokenData model.TokenData
// 	err := db.QueryRow("SELECT access_token, token_type, expires_in FROM access_tokens ORDER BY id DESC LIMIT 1").Scan(&tokenData.Access_token, &tokenData.Token_type, &tokenData.Expires_in)
// 	if err != nil {
// 		fmt.Println("查询数据失败:", err)
// 		return &tokenData, err
// 	}
// 	return &tokenData, nil
// }

// func InsertDB(db *sql.DB, accessToken string, TokenType string, expiresIn string) error {
// 	defer db.Close()

// 	_, err := db.Exec("INSERT INTO access_tokens (access_token, token_type, expires_in) VALUES (?, ?, ?)", accessToken, TokenType, expiresIn)
// 	if err != nil {
// 		fmt.Println("插入数据失败:", err)
// 		return err
// 	}
// 	return nil
// }

// func UpdateDB(db *sql.DB, accessToken string, expiresIn string) error {
// 	defer db.Close()

// 	_, err := db.Exec("UPDATE access_tokens SET access_token = ?, expires_in = ? WHERE id = 1 ", accessToken, expiresIn)
// 	if err != nil {
// 		fmt.Println("更新数据失败:", err)
// 		return err
// 	}
// 	return nil
// }

// func InsertOrUpdateDB(db *sql.DB, accessToken string, TokenType string, expiresIn string) error {
// 	defer db.Close()

// 	var count int
// 	err := db.QueryRow("SELECT COUNT(*) FROM access_tokens = 1 ").Scan(&count)
// 	if err != nil {
// 		fmt.Println("查询数据失败:", err)
// 		return err
// 	}

// 	if count == 0 {
// 		err = InsertDB(db, accessToken, TokenType, expiresIn)
// 		if err != nil {
// 			return err
// 		}
// 	} else {
// 		err = UpdateDB(db, accessToken, expiresIn)
// 		if err != nil {
// 			return err
// 		}
// 	}
// 	return nil
// }
